package com.abel.bigwater.wflow

import org.apache.kafka.clients.consumer.ConsumerRecord
import org.slf4j.LoggerFactory
import org.springframework.kafka.annotation.KafkaListener
import org.springframework.stereotype.Component

@Component
class KafkaReceiver {
    // @KafkaListener(topics = ["app_log"], groupId = "app")
    fun kafkaListener(rec: ConsumerRecord<Any, Any>) {
        lgr.info("consumer got: ${rec}")
    }

    companion object {
        private val lgr = LoggerFactory.getLogger(KafkaReceiver::class.java)
    }
}